package com.sinozo.data.common;

import org.apache.flink.streaming.api.windowing.time.Time;

public class DataConfig {

    //开发环境 ClickHouse 连接 URL
    public static final String CLICKHOUSE_URL = "jdbc:clickhouse://localhost:8123/DataCore";
    public static final String CLICKHOUSE_SERVER = "clickhouse://localhost:8123";
    public static final String CLICKHOUSE_DATABASE = "DataCore";
    public static final String CLICKHOUSE_USER = "";
    public static final String CLICKHOUSE_PASSWORD = "";
    public static final String KAFKA_SERVER = "localhost:9092";
    public static final String HDFS_SERVER = "hdfs://localhost:9000";
    public static final Integer KAFKA_PARTITION_NUM = 2;


    /**
     * 水位线设置1分钟： 1 * 60 * 1000L
     */
    public static final Long MAX_OUT_OF_ORDERLINESS = 60 * 1000L;
    //开窗时间
    public static final Time WINDOW_TIME = Time.minutes(1);
    //检查点的间隔时间单位毫秒
    public static final Long FLINK_CHECKPOINT_INTERVAL = 180 * 1000L;
    public static final Long FLINK_CHECKPOINT_TIMEOUT = 180 * 1000L;

    // ClickHouse 驱动
    public static final String CLICKHOUSE_DRIVER = "ru.yandex.clickhouse.ClickHouseDriver";

}
